# import os
# import sys
#
# # 添加导包路径
# B_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
# sys.path.insert(1, B_DIR)
# sys.path.insert(0, os.path.join(B_DIR, 'utils'))
#
# import logging
# from celery_tasks.main import celery_app
import json
import os
import sys
# path = os.path.dirname(sys.path[0])  # 得到当前项目所在目录 的绝对路径
# print('*'*50,path)
# if path and path not in sys.path:
#     sys.path.append(path)    # 把当前项目目录 ，追加到系统环境变量中

import os
import sys

import logging
from mgproject.celery_tasks.main import celery_app
B_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
sys.path.insert(1, B_DIR)
sys.path.insert(0, os.path.join(B_DIR, 'utils'))

# 为celery使⽤django配置⽂件进⾏设置
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings.dev')

logger = logging.getLogger('django')

# 为celery使用django配置文件进行设置
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings.dev')

logger = logging.getLogger('django')


@celery_app.task(name='huyi_send_sms_code')
def huyi_send_sms_code(phone, smscode_str):
    """
    发送短信异步任务
    :param phone: 手机号
    :param smscode: 短信验证码
    :return: 成功 code=2 或 失败 smsid=0
    """
    from mgproject.utils.huyi_sms.sms3 import send_sms_code
    try:
        # 调用外部接口执行发送短信任务
        ret = send_sms_code(smscode_str, phone)
        print(ret)

    except Exception as e:
        logger.error(e)

    if ret.get('code') != 2:
        logger.error(e)

    return ret.get('code', None)
